package com.beeantec.jnrerc.modules.common.service;

public interface MqService {
    boolean delayPush(String exchange, String key, Object message, Long time);
    boolean pushAndConfirm(String exchange, String key, Object message,String confirmId);
    boolean push(String exchange, String key, Object message);
    boolean pushFANOUT(String exchange, Object message);
}
